const kafka = require('kafka-node')
const client = new kafka.KafkaClient({ kafkaHost: '172.16.3.62:9092,172.16.3.65:9092,172.16.3.67:9092' });
const consumer = new kafka.Consumer(client, []);
consumer.on('message', function (message) {
  console.log('接收一条', message.value);
});
consumer.addTopics([{ topic: 'log_test', message: "test", partition: 0 }]);